package com.tuozixuan.flink.demo;

import org.apache.flink.streaming.api.TimeCharacteristic;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

public class AverageSensorReadingsSourceCustom {

	public static void main(String[] args) {

		StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
		env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);

		// 从自定义数据源读取数据
		DataStream<SensorReading> stream = env.addSource(new SensorSource());
		
		
		
	}

}
